//package com.example.java.kafka.es9client;
//
//import co.elastic.clients.elasticsearch.core.GetResponse;
//
//public class GetDoc {
//    public static void main(String[] args) {
//        ConnectElasticsearch.connect(client -> {
//            GetResponse<User> getResponse = client.get(g -> g
//                .index("user")
//                .id("1001"),
//                User.class
//            );
//            System.out.println("_index: " + getResponse.index());
//            System.out.println("_id: " + getResponse.id());
//            System.out.println("source: " + getResponse.source());
//        });
//    }
//}